// Copyright (C) 2023 即时通讯网(52im.net) & Jack Jiang.
// The RainbowChat Project. All rights reserved.
// 
// 【本产品为著作权产品，合法授权后请放心使用，禁止外传！】
// 【本次授权给：<北京小羊驼科技有限公司>，授权编号：<NT231212144350>，代码指纹：<A.702363430.550>，技术对接人微信：<ID: wxid_wbyootvkdcgj22>】
// 【授权寄送：<收件：苏先生、地址：北京市大兴区北京密码西区6号楼1单元301、电话：18613885610、邮箱：bd@huiyuanxiang-inc.com>】
// 
// 【本系列产品在国家版权局的著作权登记信息如下】：
// 1）国家版权局登记名(简称)和权证号：RainbowChat    （证书号：软著登字第1220494号、登记号：2016SR041877）
// 2）国家版权局登记名(简称)和权证号：RainbowChat-Web（证书号：软著登字第3743440号、登记号：2019SR0322683）
// 3）国家版权局登记名(简称)和权证号：RainbowAV      （证书号：软著登字第2262004号、登记号：2017SR676720）
// 4）国家版权局登记名(简称)和权证号：MobileIMSDK-Web（证书号：软著登字第2262073号、登记号：2017SR676789）
// 5）国家版权局登记名(简称)和权证号：MobileIMSDK    （证书号：软著登字第1220581号、登记号：2016SR041964）
// * 著作权所有人：江顺/苏州网际时代信息科技有限公司
// 
// 【违法或违规使用投诉和举报方式】：
// 联系邮件：jack.jiang@52im.net
// 联系微信：hellojackjiang
// 联系QQ号：413980957
// 授权说明：http://www.52im.net/thread-1115-1-1.html
// 官方社区：http://www.52im.net
package com.eva.android;

import android.util.Log;

import net.x52im.mobileimsdk.android.utils.MBThreadPoolExecutor;

import java.util.ArrayList;
import java.util.List;
import java.util.Observer;

import androidx.annotation.NonNull;
import androidx.annotation.Nullable;

/**
 * 一个观察者集合实现类，用于需要管理多个观察者的场景下。
 *
 * @author JackJiang
 * @since 8.0
 */
public class Observers {

    private final static String TAG = Observers.class.getSimpleName();
    /** 观察者列表 */
    private final List<Observer> observers = new ArrayList<>();

    public Observers(){
    }

    /**
     * 添加一个观察者。
     *
     * @param o 被添加的观察者对象
     */
    public void add(@NonNull Observer o){
        if(o != null){
            observers.add(o);
        }
        else{
            Log.w(TAG, "无效的参数，o=null！");
        }
    }

    /**
     * 移除一个观察者。
     *
     * @param o 被移除的观察者对象
     */
    public void remove(@NonNull Observer o){
        if(o != null) {
            this.observers.remove(o);
        }
        else{
            Log.w(TAG, "无效的参数，o=null！");
        }
    }

    /**
     * 清空观察者列表。
     */
    public void clear(){
        this.observers.clear();
    }

    /**
     * 通知所有观察者。
     *
     * @param datas 要通知的数据，可为空
     */
    public void notifyAll(@Nullable Object datas) {
        for (Observer obs : this.observers) {
            if(obs != null) {
                obs.update(null, datas);
            }
        }
    }

    /**
     * 返回观察者列表引用。
     *
     * @return 集合引用
     */
    public List<Observer> getObservers(){
        return this.observers;
    }
}
